//todas las consultas a la db
var pg = require('pg');
var conString = "tcp://postgres:postgres@localhost/prueba";
var client = new pg.Client(conString);
client.connect();


exports.dbListPersonas= function (cb) {
    client.query("select * from personas", cb);
};

exports.dbGetPersonas= function (id, cb) {
        client.query('SELECT * FROM personas WHERE id = $1', [id], cb);
    };

 exports.adAddPersonas = function (persona, cb) {
        client.query('INSERT INTO personas (nombre, telefono, cumpleanos) VALUES ($1, $2, $3) RETURNING *',[persona.nombre, persona.telefono, persona.cumpleanos], cb);
    };

  exports.dbUpdatePersonas=  function (persona, cb) {
        client.query('UPDATE personas set nombre=$2, telefono=$3, cumpleanos=$4 WHERE id=$1 RETURNING *',[persona.id, persona.nombre, persona.telefono, persona.cumpleanos], cb);
    };

	
  exports.dbDeletePersonas=  function (persona, cb) {
        client.query('DELETE from personas WHERE id=$1 RETURNING *',[persona.id], cb);
    };	
	
//asignaturas


exports.dbListAsignaturas= function (cb) {
    client.query("select * from asignaturas", cb);
};

exports.dbGetAsignaturas= function (id, cb) {
        client.query('SELECT * FROM asignaturas WHERE id = $1', [id], cb);
    };

 exports.adAddAsignaturas = function (asignatura, cb) {
        client.query('INSERT INTO asignaturas (nombre) VALUES ($1) RETURNING *',[asignatura.nombre], cb);
    };

  exports.dbUpdateAsignaturas=  function (asignatura, cb) {
        client.query('UPDATE asignaturas set nombre=$2, WHERE id=$1 RETURNING *',[asignatura.id, asignatura.nombre], cb);
    };

	
  exports.dbDeleteAsignaturas=  function (asignatura, cb) {
        client.query('DELETE from asignaturas WHERE id=$1 RETURNING *',[asignatura.id], cb);
    };		


exports.end=function end(cb) {
    client.end(cb);
};


//notas


exports.dbListNotas= function (cb) {
    client.query("select * from Notas", cb);
};

exports.dbGetNotas= function (id, cb) {
        client.query('SELECT * FROM Notas WHERE id = $1', [id], cb);
    };

 exports.adAddNotas = function (nota, cb) {
        client.query('INSERT INTO Notas (nota, id_persona, id_asignatura) VALUES ($1, $2, $3) RETURNING *',[nota.nota, nota.id_persona, nota.id_asignatura], cb);
    };

  exports.dbUpdateNotas=  function (nota, cb) {
        client.query('UPDATE Notas set nota=$2, WHERE id=$1 RETURNING *',[nota.id, nota.nota], cb);
    };

	
  exports.dbDeleteNotas=  function (nota, cb) {
        client.query('DELETE from Notas WHERE id=$1 RETURNING *',[nota.id], cb);
    };		



